package com.mark.common.kafka;

import org.springframework.kafka.listener.ConsumerAwareMessageListener;

/**
 * 消息监听实现接口
 * @author MAIBENBEN
 */
public interface KafkaListener<K,V> extends ConsumerAwareMessageListener<K,V> {

    /**话题
     *
     * @return
     */
    String topic();

    /**
     * 默认Kafka侦听器容器工厂
     * @return
     */
    default String factory(){
        return "defaultKafkaListenerContainerFactory";
    }

    /**
     * 违约
     * @return
     */
    default  String group(){ return "default";}

}